package com.tuozixuan.flink.demo;

import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class AverageSensorReadingsSourceFile {

	public static void main(String[] args) {

		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

		// 从文件读取数据
		String filePath = "sensor.txt";
		DataStream<String> stream = env.readTextFile(filePath);
		
	}

}
